package com.huatai.datacenter.entity;

import com.fasterxml.jackson.annotation.JsonInclude;
import lombok.Data;
import org.apache.kafka.common.record.TimestampType;

/**
 * @author Lion
 * @date 2023/6/5  15:01
 */
@Data
@JsonInclude(JsonInclude.Include.NON_NULL)
public class KafkaRecord {

	private String topic;

	private Integer partition;

	private Long timestamp;

	private TimestampType timestampType;

	private Long offset;

	private String key;

	private String value;

}
